"""
存储插件类
用于将处理后的数据存储到不同目标
"""

from abc import abstractmethod
from typing import List, Dict, Any
from .base_plugin import BasePlugin


class StoragePlugin(BasePlugin):
    """存储插件基类"""
    
    @abstractmethod
    async def connect(self) -> bool:
        """连接存储"""
        pass
    
    @abstractmethod
    async def store(self, data: List[Dict[str, Any]]) -> bool:
        """存储数据"""
        pass
    
    @abstractmethod
    async def close(self):
        """关闭连接"""
        pass